fc38d54bcbd5fb49263b80af7706598991fc52a5,core/java/src/net/i2p/internal/QueuedI2CPMessageReader.java,QueuedI2CPMessageReaderRunner,run,#,38
Before Change
if (msg.getType() == PoisonI2CPMessage.MESSAGE_TYPE)
cancelRunner();
else
_listener.messageReceived(QueuedI2CPMessageReader.this, msg);
} catch (InterruptedException ie) {}
}
// ??? unused
After Change
_listener.disconnected(QueuedI2CPMessageReader.this);
cancelRunner();
} else {
_listener.messageReceived(QueuedI2CPMessageReader.this, msg);
}
} catch (InterruptedException ie) {}
}